var app = require('express')();
var fs = require('fs');
// 创建http连接
var http = require('http').Server(app);
// 创建https连接
var https = require('https');

// 2017年1月7日20:41:46  韩东宇创建https连接的证书私钥
var privateKey  = fs.readFileSync('/data/release/nodeapp/cert/213990782620698.key', 'utf8');
var certificate = fs.readFileSync('/data/release/nodeapp/cert/213990782620698.pem', 'utf8');
var credentials = {key: privateKey, cert: certificate};
// 证书创建结束

// 开启https服务器
var httpsServer = https.createServer(credentials, app);

// 将socketio加入服务器
var io = require('socket.io')(httpsServer);

// 监听3000端口http服务
http.listen(3000, function(){
	console.log('listening on *:3000');
});

// 监听3001端口https服务
httpsServer.listen(3001, function(){
	console.log('listening on *:30011111111111111111');
});


// Welcome
app.get('/', function(req, res) {
    if(req.protocol === 'https') {
        res.status(200).send('Welcome to Safety Land!');
    }
    else {
        res.status(200).send('Welcome!');
    }
});

// *******************************************
//在线用户
var onlineUsers = {};
//当前在线人数
var onlineCount = 0;

io.on('connection', function(socket){
	console.log('a user connected');
	
	//监听新用户加入
	socket.on('login', function(obj){
		//将新加入用户的唯一标识当作socket的名称，后面退出的时候会用到
		socket.name = obj.userid;
		
		//检查在线列表，如果不在里面就加入
		if(!onlineUsers.hasOwnProperty(obj.userid)) {
			onlineUsers[obj.userid] = obj.username;
			//在线人数+1
			onlineCount++;
		}
		
		//向所有客户端广播用户加入
		io.emit('login', {onlineUsers:onlineUsers, onlineCount:onlineCount, user:obj});
		console.log(obj.username+'加入了聊天室');
	});
	
	//监听用户退出
	socket.on('disconnect', function(){
		//将退出的用户从在线列表中删除
		if(onlineUsers.hasOwnProperty(socket.name)) {
			//退出用户的信息
			var obj = {userid:socket.name, username:onlineUsers[socket.name]};
			
			//删除
			delete onlineUsers[socket.name];
			//在线人数-1
			onlineCount--;
			
			//向所有客户端广播用户退出
			io.emit('logout', {onlineUsers:onlineUsers, onlineCount:onlineCount, user:obj});
			console.log(obj.username+'退出了聊天室');
		}
	});
	
	//监听用户发布聊天内容
	socket.on('message', function(obj){
		//向所有客户端广播发布的消息
		io.emit('message', obj);
		console.log(obj.username+'说：'+obj.content);
	});
  
});